package com.service;

import io.netty.util.concurrent.Promise;

import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;

/**
 * @author 罗俊华
 * @date 2021/9/2 - 9:36 上午
 */
public class RpcPromiseContentFactory {

    /**
     * 不要将此属性声明为 static ，那样一个服务器的所有rpc调用的响应都将落到这一个 Map 中，成为性能瓶颈
     * Promise<Object> 范型如果使用通配符 ? 则 只能往里面取值，而不能往里面放值
     */
    private final Map<Integer, Promise<Object>> promiseMap = new ConcurrentHashMap<>();


    public Map<Integer, Promise<Object>> getPromiseMap() {
        return promiseMap;
    }
}
